package com.navinfo.tripanalysis.service;

import com.navinfo.tripanalysis.pojo.Point;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;

import java.util.List;

/**
 * Points 数据排序分组服务类
 * @author 沈东生
 */
public interface PointsSortGroupService {
    JavaPairRDD<Long, List<Point>> sortAndGroup(JavaRDD<Point> pointsRdd);
}
